#include"comm.hpp"

int main()
{
    int shmid = getShm();
    char *shmaddr = (char*)shmat(shmid,nullptr,0);
    
    int fd = open(FIFO_FILE, O_WRONLY); // 等待写入方打开之后，自己才会打开文件，向后执行， open 阻塞了！
    if (fd < 0)
    {
        log(Fatal, "error string: %s, error code: %d", strerror(errno), errno);
        exit(FIFO_OPEN_ERR);
    }

    //由于共享内存的地址是挂载到进程的地址空间
    //可以直接访问共享内存的起始地址
    while(true)
    {
        cout << "Please Enter@ ";
        fgets(shmaddr,Size,stdin);
        write(fd,"c",1);//通知对方
    }

    shmdt(shmaddr);
    close(fd);
    return 0;
}